package com.microlearning.common.rabbitmq.consumer;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;

/**
 * Direct(订阅)交换机：基于路由key发送给订阅了消息的对列
 * 总结(与Fanout交换机的差别)：
 *      1、Fanout交换机将消息路由给每一个与之绑定的对列
 *      2、Direct交换机根据路由key判断路由给哪个队列
 *      3、如果多个队列具有相同的路由key，则与Fanout功能类似
 */
@Service
public class DirectConsumer {

    /**
     * 获取队列消息
     */
    @RabbitListener(queues = "mic.direct.queue1")
    public String pullMessageQueue1(String message) {
        return message;
    }
    /**
     * 获取队列消息
     */
    @RabbitListener(queues = "mic.direct.queue2")
    public String pullMessageQueue2(String message) {
        return message;
    }

}
